const WebSocket = require('ws');

function main() {
    var ws = new WebSocket("ws://localhost:3001");
  //申请一个WebSocket对象，参数是服务端地址，同http协议使用http://开头一样，WebSocket协议的url使用ws://开头，另外安全的WebSocket协议使用wss://开头
  ws.onopen = function (e) {
    //当WebSocket创建成功时，触发onopen事件
    console.log("websocket连接成功");
  };
  ws.onmessage = function (e) {
    //当客户端收到服务端发来的消息时，触发onmessage事件，参数e.data包含server传递过来的数据
    console.log("收到数据", e.data);
  };
  ws.onclose = function () {
    //当客户端收到服务端发送的关闭连接请求时，触发onclose事件
    console.log("websocket已断开");
  };
  ws.onerror = function (error) {
    //如果出现连接、处理、接收、发送数据失败的时候触发onerror事件
    console.log("websocket发生错误" + error);
  };

setInterval(() => {
    const params = JSON.stringify({
      event: 'message', // => message对应着nestjs的@SubscribeMessage
      data: 'liping'
    }) 
    console.log(params)
    ws.send(params); //将消息发送到服务端
  }, 1000)

}
main()
